class websocketUtil {
  constructor(url, time) {
  /*
  url 是请求的后端的地址
  time 是心跳包的时间
  */
    this.is_open_socket = false //避免重复连接
    this.url = url //地址
    this.data = null
    //心跳检测
    this.timeout = time //多少秒执行检测
    this.heartbeatInterval = null //检测服务器端是否还活着
    this.reconnectTimeOut = null //重连之后多久再次重连

    try {
      return this.connectSocketInit()
    } catch (e) {
      console.log('catch');
      this.is_open_socket = false
      this.reconnect();
    }
  }

  // 进入这个页面的时候创建websocket连接【整个页面随时使用】
  connectSocketInit () {
    this.socketTask = uni.connectSocket({
      url: this.url,
      success: () => {
        console.log("正准备建立websocket中...");
        // 返回实例
        return this.socketTask
      },
    });
    this.socketTask.onOpen((res) => {
      console.log("WebSocket连接正常！");
      clearTimeout(this.reconnectTimeOut)
      clearTimeout(this.heartbeatInterval)
      this.is_open_socket = true;
      this.start();
      // 注：只有连接正常打开中 ，才能正常收到消息
      this.socketTask.onMessage((res) => {
        const data = JSON.parse(res.data)
        // 可以写业务逻辑，看个人的需求
        if (data.status === 200) {
          store.dispatch("changeUp", data.data)
          const { role } = store.state
          if (role) {
            const info = uni.getStorageSync("info");
            if (role !== JSON.parse(info).role) {
              uni.showModal({
                title: '温馨提示',
                content: '权限发生改变，请重新登录',
                showCancel: false,
                confirmText: '请登录',
                success (res) {
                  if (res.confirm) {
                    uni.removeStorageSync('info')
                    uni.removeStorageSync('access-token')
                    uni.navigateTo({ url: '/pages/auth/login' })
                  }
                }
              })
            }
          }
        }
        console.log(res.data)
      });
    })

    // 这里仅是事件监听【如果socket关闭了会执行】
    this.socketTask.onClose((res) => {
      if (res.code === 1000) {
        this.is_open_socket = true;
      } else {
        this.is_open_socket = false;
      }
      console.log("已经被关闭了", res)
      this.reconnect();
    })
  }

  //发送消息
  send (value) {
    // 注：只有连接正常打开中 ，才能正常成功发送消息
    this.socketTask.send({
      data: value
    });
  }
  //开启心跳检测
  start () {
    this.heartbeatInterval = setInterval(() => {
      this.data = { type: "start" }
      this.send(JSON.stringify(this.data));
      console.log('心跳包');
    }, this.timeout)
  }
  //重新连接
  reconnect () {
    //停止发送心跳
    clearInterval(this.heartbeatInterval)
    //如果不是人为关闭的话，进行重连
    if (!this.is_open_socket) {
      this.reconnectTimeOut = setTimeout(() => {
        this.connectSocketInit();
      }, 3000)
    }
  }
}

module.exports = websocketUtil
